package org.zcl.observer;

import rx.Observable;

/**
 * .
 *
 * @Author Chenglin Zhu
 * @Date 2022/2/20 10:15 下午
 */
public class TestRxJava {
    public static void main(String[] args) {

        Observable.create(emitter -> emitter.onNext("Hello World"))
                .subscribe(System.out::println);

        Observable.just("Hello World").subscribe(System.out::println);
    }


}
